/*
 * @(#)XfslPipe.java        1.0 2000/05/11
 *
 * This file is part of Xfuzzy 3.0, a design environment for fuzzy logic
 * based systems.
 *
 * (c) 2000 IMSE-CNM. The authors may be contacted by the email address:
 *                    xfuzzy-team@imse.cnm.es
 *
 * Xfuzzy is free software; you can redistribute it and/or modify it
 * under the terms of the GNU General Public License as published by
 * the Free Software Foundation.
 *
 * Xfuzzy is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
 * for more details.
 */

package xfuzzy.xfsl.model;

/**
 * Tuber�a de comunicaci�n entre el proceso de aprendizaje y la interfaz 
 * gr�fica que lo controla.
 * 
 * La interfaz env�a comandos y recibe estados y mensajes.
 * 
 * @author Francisco Jos� Moreno Velo
 *
 */
public class XfslPipe {

	//----------------------------------------------------------------------------//
	//                            COSTANTES P�BLICAS                              //
	//----------------------------------------------------------------------------//

	/**
	 * C�digo de comando: vac�o
	 */
	public static final int NOMSG=0;
	
	/**
	 * C�digo de comando: detener la ejecuci�n
	 */
	public static final int STOP=1;
	
	/**
	 * C�digo de comando: continuar la ejecuci�n
	 */
	public static final int CONTINUE=2;
	
	/**
	 * C�digo de comando: finalizar la ejecuci�n
	 */
	public static final int FINISH=3;

	//----------------------------------------------------------------------------//
	//                            MIEMBROS PRIVADOS                               //
	//----------------------------------------------------------------------------//

	/**
	 * Comando a intercambiar
	 */
	private int command=NOMSG;
	
	/**
	 * Lista de mensajes a intercambiar
	 */
	private String msg[];
	
	/**
	 * Estado a intercambiar
	 */
	private XfslStatus status;
	
	/**
	 * Indicador de nuevo estado disponible
	 */
	private boolean statusflag = false;

	//----------------------------------------------------------------------------//
	//                             M�TODOS P�BLICOS                               //
	//----------------------------------------------------------------------------//

	/**
	 * Lee el estado en la tuberia (usado por la interfaz)
	 */
	public synchronized XfslStatus get() {
		if(!statusflag) try { wait(); } catch(InterruptedException e) {}
		statusflag = false;
		notify();
		return status;
	}

	/**
	 * Escribe el estado en la tuberia (utilizado por el proceso)
	 */
	public synchronized void put(XfslStatus status) {
		if(statusflag) try { wait(); } catch(InterruptedException e) {}
		this.status = status;
		statusflag = true;
		notify();
	}

	/**
	 * Lee el comando en la tuberia (utilizado por el proceso)
	 */
	public synchronized int getCommand() {
		int last= this.command;
		this.command = NOMSG;
		return last;
	}

	/**
	 * Escribe el comando en la tuberia (usado por la interfaz)
	 */
	public synchronized void putCommand(int command) {
		this.command = command;
	}

	/**
	 * Lee el mensaje en la tuberia (usado por la interfaz)
	 */
	public synchronized String[] getMessage() {
		String[] last = this.msg;
		this.msg = null;
		return last;
	}

	/**
	 * Escribe el mensaje en la tuberia (utilizado por el proceso)
	 */
	public synchronized void putMessage(String msg) {
		this.msg = new String[1];
		this.msg[0] = msg;
	}

	/**
	 * Escribe el mensaje en la tuberia (utilizado por el proceso)
	 */
	public synchronized void putMessage(String[] msg) {
		this.msg = msg;
	}
}
